package com.jy.datapipeline.importserver.service;

import com.jy.datapipeline.common.exception.GlobalException;
import com.jy.datapipeline.common.vo.ReturnVo;
import com.jy.datapipeline.importserver.entity.ImportTaskLog;

import java.util.List;
import java.util.Set;

/**
 * @类名 TaskLogService
 * @描述 TODO
 * @作者 白条君
 * @创建日期 2023/4/19 18:10
 * @版本 1.0
 */
public interface ImportTaskLogService {

    ReturnVo queryByPage(Long pageNo, Long pageSize, String subtaskId, String taskStatus);

    void addImportTaskLog(ImportTaskLog importTaskLog) throws GlobalException;

    void deleteTaskLogsBySubtaskId(String subtaskId) throws GlobalException;

    Integer isExists(String subtaskId);

    List<String> queryTaskLogFileNames(Set<String> subtaskIds, String datFileNotExistsExp);

    void batchRemove(Set<String> subtaskIds);
}
